package com.engine4cloud.tdf.common.sse.distribute;

/**
 * 本地消息分发，直接进行发送
 *
 * @author tdf 2021/1/12
 * @version 1.0
 */
public class LocalMessageDistributor implements MessageDistributor, MessageSender {

    /**
     * 消息分发
     *
     * @param messageDO 发送的消息
     */
    @Override
    public void distribute(MessageDO messageDO) {
        doSend(messageDO);
    }

}
